#coding:utf8

# tasks --> broker  ---> worker

#进行Celery允许配置
# 为celery使用django配置文件进行设置
import os
if not os.getenv('DJANGO_SETTINGS_MODULE'):
    os.environ['DJANGO_SETTINGS_MODULE'] = 'mall.settings'


# 第一步,创建一个Celery实例对象

#第二部,通过 celery的配置文件来设置 broker

# 第三步, celery自动检测任务



from celery import Celery

# main 一般设置为脚本名字
# 也可以不设置
app = Celery('celery_tasks')

# 参数: 文件的路径
app.config_from_object('celery_tasks.config')

# 自动检测任务
# 参数: []
# 每一项 就是 对应的 celery_tasks.sms
app.autodiscover_tasks(['celery_tasks.sms','celery_tasks.email'])


# worker 执行 是在 虚拟环境同 通过指令 等待broker 分配任务

# celery -A 脚本路径.celery实例所对应的文件 worker -l info
# celery -A celery_tasks.main worker -l info